const { SuccessModule, ErrorModule } = require('./resModel')
const mysql = require("../connect/pomsql")

const resHandler = (res, result, errMsg) => {
    if (result) {
        res.json(new SuccessModule(result))
        return
    }
    res.json(new ErrorModule(errMsg))
}


// 此文件主要执行mysql语句，并对返回的值进行处理
// 这个只是简单处理并不会返回什么值
const resHandler1 = async (res, sql, errMsg) => {
    let result = null;
    try {
        result = await mysql(sql)
    } catch (err) {
        console.log(err)
    }
    // console.log(result)
    if (result && result.affectedRows === 1) {
        res.json(new SuccessModule('操作成功'))
        return
    }
    res.json(new ErrorModule(errMsg))
}

//  这个主要用于修改，和增加时返回数据使用
const resHandler2 = async (res, sql, errMsg) => {
    let result = null;
    try {
        result = await mysql(sql)
    } catch (err) {
        console.log(err)
    }

    if (result) {

        res.json(new SuccessModule(result))
        return
    }
    res.json(new ErrorModule(errMsg))
}

// 主要用来获取数据
const resHandler3 = async (res, sql, errMsg) => {
    let result = null;
    try {
        result = await mysql(sql)
    } catch (err) {
        console.log(err)
    }
    if (result) {
        return result[0]
    }
    res.json(new ErrorModule(errMsg))
}



module.exports = {
    resHandler,
    resHandler1,
    resHandler2,
    resHandler3
}
